//package com.gtp.mq.demo.expands;
//
//import org.springframework.amqp.AmqpException;
//import org.springframework.amqp.core.Message;
//import org.springframework.amqp.core.MessagePostProcessor;
//
///**
// * 发消息时,可以对消息拦截
// * 消息前置处理器:可以统一加前置消息等
// */
//public class MyMessagePostProcessor implements MessagePostProcessor{
//
//	@Override
//	public Message postProcessMessage(Message message) throws AmqpException {
//		System.out.println("发:"+message);
//		return message;
//	}
//
//}
